#!/bin/bash
# 作用：启/停Flume通道（Kafka业务数据 -> HDFS）
if [ $# -ne 1 ]
then
	echo "请输入正确指令start/stop" && exit
fi

FLUME_HOME=/opt/module/flume-1.9.0

case $1 in
"start")
	echo "========== 启动hadoop104的flume通道（业务数据） =========="
	ssh hadoop104 "nohup $FLUME_HOME/bin/flume-ng agent -n a1 -c $FLUME_HOME/conf -f $FLUME_HOME/job/kafka_to_hdfs_db.conf >/dev/null 2>&1 &"
;;
"stop")
	echo "========== 关闭hadoop104的flume通道（业务数据） =========="
	ssh hadoop104 "ps -ef | grep kafka_to_hdfs_db.conf | grep -v grep | awk '{print \$2}' | xargs kill -9"

;;
*)
	echo "请输入正确指令start/stop" && exit
;;
esac